package com.innodealing.kafka.annotation;

import java.lang.annotation.*;

/**
 * Hermes订阅监听器
 * @author Yinpenghai
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface HermesKafkaListener {
    /**
     * 订阅的主题
     * @return 订阅的主题
     */
    String[] topics() default {};

    /**
     * 消费组
     * @return 消费组
     */
    String groupId() default "";
}
